package com.fcat.springboot.mqtt.emqx;

import org.eclipse.paho.client.mqttv3.MqttMessage;

public interface MessageDealService {
    public void messageArrived(String topic, MqttMessage message);

}
